import com.tsx.kafka.product.KafkaUtil;

public class kafkaProductDemo {

	
	public static void main(String[] args) throws Exception {
		  int partition=0;
		for (int i = 0; i < 30330; i++) {
			KafkaUtil.send("yiweiCarMes",partition,"carNowFlag", "我是测试用例"+i);
		}
		
	}
}
